package aps

/**
 * Created by Administrator on 2018-04-24.
 */
class ObserverListener implements Observer {

    //def  TopicMsgThreadService run

    @Override
    void update(Observable o, Object arg) {
        System.out.println("监听异常准备重启...............");
        TopicMsgThreadService run = new TopicMsgThreadService();
        run.addObserver(this);
        new Thread(run).start();
        System.out.println("监听Topic重启完成..............");
    }
}
